package com.yq.canalkafka.service;

import com.alibaba.otter.canal.protocol.CanalEntry;

import java.util.List;

/**
 * @author by shizan
 * @Classname CanalSqlService
 * @Description sql拼接service
 * @Date 2020/11/23 4:35 下午
 */
public interface CanalSqlService {
    /**
     * 获取Insert sql
     *
     * @param columnsList
     * @param tableName
     * @return
     */
    String getInsertSql(List<CanalEntry.Column> columnsList, String tableName);

    String getUpdateSql(List<CanalEntry.Column> afterColumnsList, String tableName);
}
